c93d7cf48379ca95d65303de73d52a20fdf541a8,src/main/java/io/vertx/ext/asyncsql/impl/AsyncSQLConnectionImpl.java,AsyncSQLConnectionImpl,query,#String#Handler#,60
Before Change
@Override
public SQLConnection query(String sql, Handler<AsyncResult<ResultSet>> handler) {
beginTransactionIfNeeded().flatMap((res) -> {
connection.sendQuery(sql);
}).onComplete(done(handler, queryResultToUpdateResult));
return this;
}
After Change
@Override
public SQLConnection query(String sql, Handler<AsyncResult<ResultSet>> handler) {
beginTransactionIfNeeded().setHandler(v -> {
final scala.concurrent.Future<QueryResult> future = connection.sendQuery(sql);
future.onComplete(ScalaUtils.<QueryResult>toFunction1(ar -> {
if (ar.succeeded()) {
handler.handle(Future.succeededFuture(queryResultToResultSet(ar.result())));
} else {
handler.handle(Future.failedFuture(ar.cause()));
}
}),executionContext);
});
return this;
}